|
rocketmq-spring-boot-starter之消费者消息确认
skyscraper97:
`onMessage` 是被调用的。
源码举例：
类：DefaultMessageListenerConcurrently
[code=java]
public ConsumeConcurrentlyStatus consumeMessage(List msgs, ConsumeConcurrentlyContext context) {
...
handleMessage(messageExt);
...
} catch (Exception e) {
log.warn("consume message failed. messageExt:{}, error:{}", messageExt, e);
context.setDelayLevelWhenNextConsume(delayLevelWhenNextConsume);
return ConsumeConcurrentlyStatus.RECONSUME_LATER;
}
}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
[/code]
`handleMessage` 方法中
|